
let mysql  = require('mysql');

let pool = mysql.createPool({
    connectionLimit:40,//连接池最多可以创建连接数
    host:'127.0.0.1',
    user:'root',
    database:'ResourceManage',
    password:'Xlb65386538',
    queueLimit:300 // 队伍中等待连接的最大数量，0为不限制。
});

//创建一个连接，超过connectionLimit，会调用下面 'enqueue' 等待队列
pool.on('connection',function(){
    console.log('创建一个连接');
});

// 超过连接池连接数量 进入等待队列
pool.on('enqueue',function(){
    console.log('进入等待队列');
});

exports.executeSql = function(sql,callBack) {
    pool.getConnection(function (err,conn) {
        if (err)
        {
            callBack(err,null);
            console.log(err.message);
        }
        else
        {
            conn.query(sql,function (err,result) {

                callBack(err,result);
                conn.release();//释放连接池
            })
        }
    })
};
